package org.cancer.controller

import org.apache.spark.streaming.dstream.DStream
import org.cancer.bean.HighRiskIdentificationData
import org.cancer.service.HighRiskIdentificationService_Sylvia

class HighRiskIdentificationController {
  private val highRiskService = new HighRiskIdentificationService_Sylvia()

  def dispatch(dataStream: DStream[HighRiskIdentificationData]): Unit = {
    println("接收到患者数据流，开始处理...")
    highRiskService.dataAnalysis(dataStream)
  }
}
